fairnesscoop / pictyschool

@CommandHandler(CreateSchoolCommand)

export class CreateSchoolCommandHandler {

  constructor(

    @Inject('ISchoolRepository')

    private readonly schoolRepository: ISchoolRepository,

    @Inject('IEventBus')

    private readonly eventBus: IEventBus,

    private readonly isSchoolAlreadyExist: IsSchoolAlreadyExist

  ) {}

  public async execute(command: CreateSchoolCommand): Promise<string> {

    const {

      reference,

      address,

      city,

      name,

      zipCode,

      email,

      numberOfClasses,

      numberOfStudents,

      status,

      type, 

      observation,

      phoneNumber

    } = command;

    if (true === (await this.isSchoolAlreadyExist.isSatisfiedBy(reference))) {

      throw new SchoolAlreadyExistException();

    }

    const school = await this.schoolRepository.save(

      new School(

        reference,

        name,

        address,

        zipCode,

        city,

        status,

        type,

        email,

        phoneNumber,

        numberOfStudents,

        numberOfClasses,

        observation

      )

    );

    this.eventBus.publish(new SchoolCreatedEvent(school.getId()));

    return school.getId();